package org.qing.freepx.service;

import org.qing.freepx.entity.IPProxy;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface IPProxyService {

	Mono<String> test();

	Flux<IPProxy> createOrUpdate(Flux<IPProxy> iPProxys);

	Mono<IPProxy> createOrUpdate(IPProxy iPProxy);

	Mono<IPProxy> deleteById(String ip);

	Flux<IPProxy> getIPProxyBeanList(Flux<String> ips);

	Mono<IPProxy> getIPProxyBeanById(String ip);

	Flux<IPProxy> getAllIPProxyBeanList();

}
